package com.gather.zx;

public class Consumer implements Runnable {
	private Center center;

	public Consumer(Center center) {  
        this.center = center;  
    }  
  
    @Override  
    public void run() {  
        while (!Thread.interrupted()) {  
            center.consume();  
        }  
    }  


}
